github.com/go-pg/pg/v10.Tx.db (field)
21 uses
github.com/go-pg/pg/v10 (current package)
tx.go#L30: db *baseDB
tx.go#L53: db: db.withPool(pool.NewStickyConnPool(db.pool)),
tx.go#L105: err := tx.db.withConn(c, fn)
tx.go#L132: db := tx.db.withPool(pool.NewStickyConnPool(tx.db.pool))
tx.go#L156: if err := writeQueryMsg(wb, tx.db.fmter, query, params...); err != nil {
tx.go#L160: ctx, evt, err := tx.db.beforeQuery(ctx, tx, nil, query, params, wb.Query())
tx.go#L167: res, err = tx.db.simpleQuery(ctx, cn, wb)
tx.go#L171: if err := tx.db.afterQuery(ctx, evt, res, lastErr); err != nil {
tx.go#L223: if err := writeQueryMsg(wb, tx.db.fmter, query, params...); err != nil {
tx.go#L227: ctx, evt, err := tx.db.beforeQuery(ctx, tx, model, query, params, wb.Query())
tx.go#L234: res, err = tx.db.simpleQueryData(ctx, cn, model, wb)
tx.go#L238: if err := tx.db.afterQuery(ctx, evt, res, err); err != nil {
tx.go#L294: res, err = tx.db.copyFrom(c, cn, r, query, params...)
tx.go#L303: res, err = tx.db.copyTo(c, cn, w, query, params...)
tx.go#L311: return tx.db.Formatter()
tx.go#L316: for attempt := 0; attempt <= tx.db.opt.MaxRetries; attempt++ {
tx.go#L318: if err := internal.Sleep(ctx, tx.db.retryBackoff(attempt-1)); err != nil {
tx.go#L322: err := tx.db.pool.(*pool.StickyConnPool).Reset(ctx)
tx.go#L329: if !tx.db.shouldRetry(lastErr) {
tx.go#L383: _ = tx.db.Close()